package com.xiaoze.function;

import com.xiaoze.bean.WaterSensor;
import org.apache.flink.api.common.functions.FilterFunction;

/**
 * @author 小泽
 * @create 2024-09-02  15:21
 * 记得每天敲代码哦
 */
public class MyFilterFunctionImpl implements FilterFunction<WaterSensor> {
       @Override
       public boolean filter(WaterSensor value) throws Exception {
              return "s1".equals(value.getId());
       }
}
